//   Copyright 2012,2013 Vaughn Vernon
//
//   Licensed under the Apache License, Version 2.0 (the "License");
//   you may not use this file except in compliance with the License.
//   You may obtain a copy of the License at
//
//       http://www.apache.org/licenses/LICENSE-2.0
//
//   Unless required by applicable law or agreed to in writing, software
//   distributed under the License is distributed on an "AS IS" BASIS,
//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//   See the License for the specific language governing permissions and
//   limitations under the License.

package com.saasovation.agilepm.port.adapter.messaging.rabbitmq;

import java.util.Date;

import com.saasovation.agilepm.application.team.ChangeTeamMemberNameCommand;
import com.saasovation.agilepm.application.team.TeamApplicationService;
import com.saasovation.common.notification.NotificationReader;
import com.saasovation.common.port.adapter.messaging.Exchanges;
import com.saasovation.common.port.adapter.messaging.rabbitmq.ExchangeListener;

/**
 * RabbitMQ团队成员名改变监听器
 * @author learn
 */
public class RabbitMQTeamMemberNameChangedListener extends ExchangeListener {
    /**
     * 团队应用服务
     */
    private TeamApplicationService teamApplicationService;

    /**
     * 默认构造器
     */
    public RabbitMQTeamMemberNameChangedListener() {
        super();
    }

    /**
     * 获取回答监听到的交换名
     * @return      返回字符串
     */
    @Override
    protected String exchangeName() {
        return Exchanges.IDENTITY_ACCESS_EXCHANGE_NAME;
    }

    /**
     * 已删选的分配
     * @param aType the String message type
     * @param aTextMessage the String raw text message being handled
     */
    @Override
    protected void filteredDispatch(String aType, String aTextMessage) {
        // 通知阅读器
        NotificationReader reader = new NotificationReader(aTextMessage);

        // 使用此阅读器读取对应的值
        String firstName = reader.eventStringValue("name.firstName");
        String lastName = reader.eventStringValue("name.lastName");
        String tenantId = reader.eventStringValue("tenantId.id");
        String username = reader.eventStringValue("username");
        Date occurredOn = reader.occurredOn();

        // 使用团队应用服务来改变团队成员名
        this.teamApplicationService().changeTeamMemberName(
                new ChangeTeamMemberNameCommand(
                    tenantId,
                    username,
                    firstName,
                    lastName,
                    occurredOn));
    }

    /**
     * 监听...
     * @return      返回字符串数组
     */
    @Override
    protected String[] listensTo() {
        return new String[] {
                "com.saasovation.identityaccess.domain.model.identity.PersonNameChanged"
                };
    }

    /**
     * 获取团队应用服务
     * @return      返回团队应用服务
     */
    private TeamApplicationService teamApplicationService() {
        return this.teamApplicationService;
    }
}
